package com.spyz.hdfs_api;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;

import java.net.URI;

public class P1_Hdfs_api_mkdir_1 {
    /**
     * 客户端代码常见流程
     * 1、获取一个客户端对象
     * 2、执行相关的操作命令
     * 3、关闭资源
     */
    public static void main(String[] args) throws Exception {

        // 链接集群nn地址
        URI uri = new URI("hdfs://master:8020");
        // 创建一个配置文件
        Configuration conf = new Configuration();

        // 用户
        String user = "root";

        // 获取到客户端对象
        FileSystem fs = FileSystem.get(uri, conf,user);

        // 创建一个文件夹
        fs.mkdirs(new Path("/hdfs_api"));

        // 关闭资源
        fs.close();
    }
}
